package com.kafka.entity;

import lombok.Data;
import org.springframework.stereotype.Component;

import java.io.Serializable;
import java.util.Date;

/**
 * @ClassName com.itcat.Message
 * @Description TODD
 * @Author Jesson
 * @Date 2019/1/14 14:46
 * @Version 1.0
 **/
@Data
@Component
public class Message implements Serializable {
    /**
     * UUID
     */
    private String id;
    /**
     * 消息体
     */
    private byte[] msg;
    /**
     * 发送消息的时间
     */
    private Date sendTime;
    /**
     * 消息接收时间
     */
    private String receiceTime;

    /**
     * 通信IP地址
     */
    private String addr;

    /**
     * 通信端口号
     */
    private String port;

    /**
     * 消息处理状态
     */
    private String status;
    /**
     * 消息请求回复标记,true:请求,false:回复
     */
    private boolean bReq;
    /**
     *报文生命周期,单位秒
     */
    private int txnLife;
}
